package org.apache.flink.runtime.consumermanager;

import org.apache.flink.runtime.allocation.ResourceAllocation;

/** Interface for completion actions once a consumption has reached a terminal state. */
public interface OnCompletionActions {

    /**
     * consume reached a globally terminal state.
     *
     * @param executionGraphInfo contains information about the terminated job
     */
    void consumeReachedGloballyTerminalState(ResourceAllocation allocation);

    /** The {@link JobMaster} failed while executing the job. */
    void resourceConsumerFailed(Throwable cause);
}
